package com.camemax.rabbitmq.direct_mode;


import com.camemax.rabbitmq.utils.ConsumersModulesRunnable;

public class DirectMode_Consumer extends ConsumersModulesRunnable {
    public DirectMode_Consumer(String queueName) {
        super(queueName);
    }

    public static void main(String[] args) {
        String queue01 = "direct-queue01";
        String queue02 = "direct-queue02";
        String queue03 = "direct-queue03";
        new Thread(new ConsumersModulesRunnable(queue01), "direct-queue01").start();
        new Thread(new ConsumersModulesRunnable(queue02), "direct-queue02").start();
        new Thread(new ConsumersModulesRunnable(queue03), "direct-queue03").start();
    }
}
